package flink_p1

import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment}

/**
 * word count将结果写入mysql
 *
 */

object FlinkTest_12_Sink_Socket {


  def main(args: Array[String]): Unit = {


    val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment


    val socketStream: DataStream[String] = env.socketTextStream("127.0.0.1", 8889)


    /**
     *
     */

    env.execute("redis test...")

  }

}
